11d5eef0dcdcaa9f0c79862d0efe54c593f8a4c9,src/org/jgroups/protocols/pbcast/NAKACK.java,NAKACK,handleMessage,#Message#NakAckHeader#,782
Before Change
for(final Message msg_to_deliver: msgs) {
// discard OOB msg if it has already been delivered (http://jira.jboss.com/jira/browse/JGRP-379)
if(msg_to_deliver.isFlagSet(Message.OOB)) {
if(msg_to_deliver.setTransientFlagIfAbsent(Message.OOB_DELIVERED)) {
timer.execute(new Runnable() {
public void run() {
up_prot.up(new Event(Event.MSG, msg_to_deliver));
}
});
}
continue;
}
num_regular_msgs_removed++;
// Changed by bela Jan 29 2003: not needed (see above)
After Change
for(final Message msg_to_deliver: msgs) {
// discard OOB msg if it has already been delivered (http://jira.jboss.com/jira/browse/JGRP-379)
if(msg_to_deliver.isFlagSet(Message.OOB) && !msg_to_deliver.setTransientFlagIfAbsent(Message.OOB_DELIVERED))
continue;
//msg_to_deliver.removeHeader(getName()); // Changed by bela Jan 29 2003: not needed (see above)
try {
up_prot.up(new Event(Event.MSG, msg_to_deliver));